const { Kafka } = require('kafkajs');

const topic = 'LOGIN-MESSAGE';

// 创建 Kafka 生产者
async function produce() {
    const kafka = new Kafka({
        clientId: 'producer',
        brokers: ['localhost:9092']
    });

    // 创建和连接生产者实例
    const producer = kafka.producer();
    await producer.connect();

    // 发送消息
    await producer.send({
        topic,
        messages: [
            { value: 'Hello Kafka!' }
        ]
    });

    // 断开连接
    await producer.disconnect();
}

// 运行生产者和消费者
async function run() {
    await produce();
}

run().catch(console.error);
